package com.iot.mqtt;

/**
 * MqttListener适配器，简化实现
 *
 * @author 田
 */
public class MqttListenerAdapter implements MqttListener {
    @Override
    public void onConnected(MqttHelper helper, String serverURI) {
        // 默认实现，子类可重写
        // 可以在这里处理连接成功后的逻辑
        System.out.println("Connected to MQTT server: " + serverURI);
    }

    @Override
    public void onMessage(String topic, int qos, String message) {
        // 默认实现，子类可重写
        // 可以在这里处理接收到的消息
        System.out.println("Received message on topic " + topic + ": " + message);
    }

    @Override
    public void onConnectionLost(Throwable cause) {
        // 默认实现，子类可重写
        // 可以在这里处理连接丢失的逻辑
        System.err.println("Connection lost: " + cause.getMessage());
    }

    @Override
    public void onDeliveryComplete(String[] topics, String message) {
        // 默认实现，子类可重写
        // 可以在这里处理消息发送完毕的逻辑
        System.out.println("Delivery complete for topics: " + String.join(", ", topics) + " with message: " + message);
    }
}
